package com.hung.tripleregistry.dao;

import com.hung.tripleregistry.core.model.RpcRegistryMessage;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;

import java.util.List;

/**
 * @author Hung
 * @date 2022/10/3 21:33
 */
@Mapper
public interface RpcRegistryMessageMapper {

    int add(@Param("rpcRegistryMessage") RpcRegistryMessage rpcRegistryMessage);

    List<RpcRegistryMessage> findMessage(@Param("excludeIds") List<Integer> excludeIds);

    int cleanMessage(@Param("messageTimeout") int messageTimeout);

}
